/**
 * @author 陈泰来
 * @version V1.0
 * @Project echo-java-base
 * @Title 生产者
 * @Description *
 * @Package concurrent.blockingQueue.bqtest4
 * @date 2021/3/23 2:11 下午
 * @Copyright:学如逆水行舟，不进则退 .
 */
package concurrent.blockingQueue.bqtest4;

public class Producer implements Runnable {

    BQTestQueue4<String> bqTestQueue4;

    //构造
    public Producer(BQTestQueue4<String> bqTestQueue4) {
        this.bqTestQueue4 = bqTestQueue4;
    }

    @Override
    public void run() {
        int count = 0;
        for (; ; ) {
            bqTestQueue4.push("推送第" + count + "条msg");
            count++;
        }

    }
}
